import redis
import datetime
import json
client = redis.Redis()
while True:  # 使用一个无限循环来实现持续发布消息。
    message = input('请输入需要发布的信息：')  # 让用户在命令行输入需要发布的信息。
    now_time = datetime.datetime.now().strftime('%Y-%m-%d %H:%M:%S')  # 记录当前 的时间
    data = {'message': message, 'time': now_time}  # 把信息和时间组装为一个字典。
    client.set('message', json.dumps(data))  # 以 JSON 格式把信息设置到 Redis 的message 字符串中
